ee0f0c418dfcc8e65e1ae6783385bd6f399b5346,community/kernel/src/test/java/org/neo4j/unsafe/impl/batchimport/store/io/WriteQueueTest.java,WriteQueueTest,shouldDrainAllOfferedAtOnce,#,64

Before Change


        // GIVEN
        ExecutorService executor = mock( ExecutorService.class );
        JobMonitor jobMonitor = new JobMonitor();
        WriteQueue queue = new WriteQueue( executor, jobMonitor );
        assertFalse( jobMonitor.hasActiveJobs() );

        // WHEN/THEN
        WriteJob job1 = mock( WriteJob.class );
        WriteJob job2 = mock( WriteJob.class );
        queue.offer( job1 );
        queue.offer( job2 );
        assertArrayEquals( new WriteJob[] {job1, job2}, queue.drain() );
        verify( executor, times( 1 ) ).submit( any( Callable.class ) );
        reset( executor );

After Change


        assertFalse( jobMonitor.hasActiveJobs() );

        // WHEN
        queue.offer( JOB1 );
        queue.offer( JOB2 );

        // THEN